Simplified Http This is a fully featured http client for Scala which wraps java.net.HttpURLConnecti ...

一、为什么引入有限状态机？ 　 最近做一个项目，项目中很多实体(Entity)，每个实体都有很多状态(State)，各状态会经过不同事件(Event)触发后转换到另一个状态。这些事件包括但不限于 ...

最近一个项目，需要操作近70亿数据进行统计分析。如果存入MySQL，很难读取如此大的数据，即使使用搜索引擎，也是非常慢。经过调研决定借助我们公司大数据平台结合Spark技术完成这么大数据量的统计分析。 ...

1.顺序读写 kafka的消息是不断追加到文件中的，这个特性使kafka可以充分利用磁盘的顺序读写性能 顺序读写不需要硬盘磁头的寻道时间，只需很少的扇区旋转时间，所以速度远快于随机读写 生产者负 ...

本篇文章主要让大家理解什么是Scala的反射, 以及反射的分类, 反射的一些术语概念和一些简单的反射例子. 什么是反射 我们知道, Scala是基于JVM的语言, Scala编译器会将Scala代 ...

　　最近使用Flink实时告警项目，开始case by case硬编码定义算子，进行实时计算告警是没问题。但是业务场景结合规则引擎动态增删改规则并实时生效计算并告警。Flink并不支持动态添加，修改算 ...

下面提供三种计时器的写法供大家参考，大家可以自行选择自己钟爱的使用。 写法一（Spring 包提供的计时器）： 下面写一个调用： 运行结果： sw. ...

关键词： 1. 定时任务 2. 分布式 3. 可动态配置触发时间 一般通过Quartz实现定时任务很简单。如果实现分布式定时任务需要结合分布式框架选择master节点触发也可以实现。但我们有个 ...

阿里Canal项目请先了解：canal 考虑可能binlog大批量变更，如果直接通过Canal订阅binlog变动，会造成CanalClient会瞬间爆掉。为了解决这个问题，我们可以引入kafka做 ...

用过Scala的模式匹配，感觉Java的弱爆了。Scala几乎可以匹配任何数据类型，如果默认的不能满足你的要求，你可以自定义模式匹配。 介绍Scala的模式匹配前，我们先了解清楚unapply()与 ...